這是以訂閱MQTT為例:

{
    "name": "mqtttest",
    "config": {
        "connector.class": "io.confluent.connect.mqtt.MqttSourceConnector",
        "tasks.max": 1,
        "mqtt.server.uri": "填上你mqtt伺服網址",
        "mqtt.topics": "Test/room",
        "kafka.topic": "testroom",
        "value.converter": "org.apache.kafka.connect.converters.ByteArrayConverter",
        "confluent.topic.bootstrap.servers": "broker:29092",
        "confluent.topic.replication.factor": 1
    }
}

connector.class: 這指定了要使用的連接器類，這里是 MQTT 源連接器。
tasks.max: 這指定了此連接器實例所運行的最大任務數。在這種情況下，最多允許一個任務運行。
mqtt.server.uri: 這是 MQTT 代理服務器的 URI，指定了 MQTT 服務器的地址和端口。
mqtt.topics: 這是要訂閱的 MQTT 主題。連接器將從這個主題接收數據。
kafka.topic": 這是將數據發送到 Kafka 主題的名稱。連接器會將從 MQTT 主題接收到的數據傳輸到這個 Kafka 主題中。
value.converter，org.apache.kafka.connect.converters.ByteArrayConverter: 這指定了數據值的轉換器。在此示例中，數據將以字節數組的形式傳輸。
confluent.topic.bootstrap.servers:這是 Confluent 平台的 Kafka 集群的引導服務器地址，用於連接到 Kafka 集群。
confluent.topic.replication.factor: 這指定了 Kafka 主題的覆制因子，即主題數據的備份數。在這里，設置為 1，表示不進行數據備份。

明天講解如何啟用這支檔案與介紹Crul。